# backend/celery.py
import os
from celery import Celery

# 设置 Django 的环境变量
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'backend.settings')

# 猴子补丁
# import eventlet
# eventlet.monkey_patch()
# from .logging_config import setup_logging
#
# setup_logging()  # 确保 Celery 加载 Django 的日志配置

app = Celery('backend')

# 从 Django 的设置中加载配置
app.config_from_object('django.conf:settings', namespace='CELERY')

# 自动查找任务
app.autodiscover_tasks()


# 一个测试任务
@app.task(bind=True)
def debug_task(self):
    print(f'Request: {self.request!r}')